#
# 读取2019gwy excel文件，将数据写入mysql数据库
#
import xlrd
#import xlwt
#from datetime import date,datetime
import datetime
import conn_mysqldb_gwy as mysqldb


#读取2018sjb excel文件
def read_excel():
	workbook=xlrd.open_workbook("2019gwy.xls")
	#--连接数据库--
	db=mysqldb.conn_db()
	#获取数据库游标
	cursor=mysqldb.get_cursor(db)
	
	#遍历所有sheet工作表
	for si in range(0,4):
		sheet=workbook.sheet_by_index(si)  #sheet索引，获取sheet
		print("sheet",(si+1),"名称：",sheet.name,"共",sheet.nrows,"行",sheet.ncols,"列")
		#对每个sheet中数据进行处理
		headers=[]
		for hi in range(0,sheet.ncols):
			headers.append(sheet.cell_value(1,hi))  #表头在1行
		#print(headers)  #打印表头
		#遍历每行数据
		for ri in range(2,sheet.nrows):
			#遍历每一列数据
			row_datas=[]
			sql="insert into gwy2019(bmdm,bmmc,yrsj,jgxz,zkzw,zwsx,zwfb,zwjj,zwdm,jgcj,kslb,zkrs,zhuanye,xueli,xuewei,zzmm,zdnx,fwjcjl,zycs,msbl,gzdd,lhdd,beizhu,bmwz,phone1,phone2,phone3) values("
			
			for li in range(0,sheet.ncols):
				row_datas.append(sheet.cell_value(ri,li))  #组header
				if li == 11:
					sql=sql+sheet.cell_value(ri,li)
				else:
					sql=sql+"'"+sheet.cell_value(ri,li).strip()+"'"
				if li<sheet.ncols-1:
					sql=sql+","
			sql=sql+")"
			#print(row_datas)
			#print(sql)
			#写入数据库
			res=mysqldb.execute(cursor, sql.encode("utf-8"))
			#print(res)
	
	#--关闭数据库连接--
	mysqldb.close_db(db)

if __name__ == '__main__':
    read_excel()
